#!coding=utf-8
import time

from celery import Celery

# from apps import get_app
#
# app = get_app()
#
# # 第一个参数 是当前脚本的名称，第二个参数 是 broker 服务地址
app = Celery('tasks', backend='redis://127.0.0.1/3', broker='redis://127.0.0.1/4')


@app.task
def add(x, y):
    print(x, y)
    time.sleep(100)
    print('end', x, y)
    return x + y
